#include "mqtt2ros.hpp"

int main(int argc, char** argv) {

    // // 初始化MQTT客户端
    // mqtt2ros::mqtt_interface mqtt_client("tcp://localhost:1883", "mqtt2ros_client", "/rig6/down/pos");
    // if (!mqtt_client.connect()) {
    //     // RCLCPP_ERROR(rclcpp::get_logger("mqtt2ros_node"), "MQTT连接失败");
    //     return 1;
    // }

    // 初始化ROS2
    rclcpp::init(argc, argv);

    // 创建节点
    auto node = std::make_shared<mqtt2ros::Mqtt2Ros>();

    // 启动ROS2消息处理
    rclcpp::spin(node);

    // 清理资源
    rclcpp::shutdown();
    return 0;
}
